package com.k.activemq.openwire4.domain;

public class ConnData {
    // failover:(tcp://primary:61616,tcp://secondary:61616)?randomize=false
    // 89
//    public static final String url = "tcp://192.168.241.89:22000";
//    public static final String username = "admin";
//    public static final String password = "Command_123";

    // local
    public static final String url = "tcp://localhost:61616";
    public static final String username = "admin";
    public static final String password = "admin";

    public static final String publishTopic = "test20240522";
    public static final String[] listenerTopics = new String[]{"test20240522"};

    // 如果 true 则会创建 Topic, 否则是 Queue
    public static final boolean pubSubDomain = true;

    public static class PubConfig{
        // 数据持久化, Broker宕机或停止服务内存中的数据不丢失
        // 需要 Broker 配置持久化策略 KaHaDB LevelDB MySql
        public static final Boolean persistentData = true;
    }
    public static class SubConfig{
        // 持久订阅 消费者断线,再上线,继续能收到消息
        public static final Boolean durableSubscription = false;
    }

}
